c6ea17555adfc325c0ec995d59c8d14a9dac2ad1,distributedlog-service/src/main/java/com/twitter/distributedlog/service/MonitorService.java,MonitorService,runMonitor,#DistributedLogConfiguration#URI#,395
Before Change
void runMonitor(DistributedLogConfiguration conf, URI dlUri) throws IOException {
// stats
statsProvider.getStatsLogger("monitor").registerGauge("num_streams", new org.apache.bookkeeper.stats.Gauge<Number>() {
@Override
public Number getDefaultValue() {
return 0;
}
@Override
public Number getSample() {
return knownStreams.size();
}
});
logger.info("Construct dl namespace @ {}", dlUri);
dlNamespace = DistributedLogNamespaceBuilder.newBuilder()
.conf(conf)
After Change
void runMonitor(DistributedLogConfiguration conf, URI dlUri) throws IOException {
// stats
statsProvider.getStatsLogger("monitor").registerGauge("num_streams", numOfStreamsGauge);
logger.info("Construct dl namespace @ {}", dlUri);
dlNamespace = DistributedLogNamespaceBuilder.newBuilder()
.conf(conf)